package org.example.mq.common;

import org.example.mq.brokerserver.core.BasicProperties;

import java.io.IOException;

//函数式接口/回调函数，收掉消息后处理消息时调用的方法
@FunctionalInterface
public interface Consumer {
    //通过这个方法将消息推给对应的消费者
    //这个方法是每次服务器收到消息后进行调用。
     void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] payload) throws MqException, IOException;
}
